package ltd.dujiabao.activemq.spring.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

/**
 * @author : DuJiabao
 * @Project : active-mq
 * @Time : 2021/5/6 10:45
 * @Desc :
 */
@Service
public class ActiveMQProducer {
  @Autowired
  private JmsTemplate jmsTemplate;

  /**
   * 也就是说， 只要生产一个消息就好，其他的事，不用自己管。
   *
   * @param text
   */
  public void sendText(String text) {
    jmsTemplate.send((session) -> session.createTextMessage(text));
    System.out.println("发送消息：" + text + " 成功");
  }
}
